package rqueue

//type RqueueClient interface {
//	Push(v interface{}) error
//}
//
////封装的生产者客户端
//type rqueueSvcClient struct {
//	pusher rocket.Pusher
//}
//
//func NewKqueueSvcClient(pusher rocket.Pusher) RqueueClient {
//	return &rqueueSvcClient{
//		pusher: pusher,
//	}
//}
//func (p *rqueueSvcClient) Push(v interface{}) error {
//
//	// marshal
//	body, err := jsonx.Marshal(v)
//	if err != nil {
//		return errors.Wrapf(errorx.NewDefaultError("rocket task marshal error "), "【pushRqMsgErrorMarshal】tag : %s , v : %+v", p.pusher.Tag, v)
//	}
//
//	if err := p.pusher.Push(string(body)); err != nil {
//		return errors.Wrapf(errorx.NewDefaultError("rocket mqs push message error"), " 【pushRqMsgError】 tag : %s , v : %v", p.pusher.Tag, v)
//	}
//
//	return nil
//}
